+ [AFF-MIGRATION-103] Создать TBD

Контракт данных топика Kafka контура фиксации пересчета матрицы

Author

Services Task & Simulation Framework Documentation

Published

July 13, 2026

NoteКраткая карточка задачи
  • Репозиторий / Компонент: Apache Kafka Cluster (Канонические топики).
  • Формат: JSON Schema.
  • Ссылка на Метод: Спецификация метода
  • Статус: Готово к реализации
  • Спецификации контракта:
1. Общий топик аналитических событий инвентаря bpds.pma.out.process.event
  • Применение: Асинхронный пуш уведомления о пересчете/мутации матрицы рекомендаций (Шаг 9) в bupar-audit-service для фиксации шага AFFINITY_MATRIX_MUTATED в сквозном аудите PMA. Название топика приведено в строгое соответствие с Разделом 2 архитектурного манифеста.
{
  "\$schema": "https://json-schema.org",
  "title": "AffinityMatrixMutatedEvent",
  "type": "object",
  "required": ["trace_id", "case_id", "event_type", "timestamp", "payload"],
  "properties": {
    "trace_id": { "type": "string" },
    "case_id": { "type": "string" },
    "event_type": { "type": "string", "const": "AFFINITY_MATRIX_MUTATED" },
    "timestamp": { "type": "string", "format": "date-time" },
    "payload": {
      "type": "object",
      "required": ["user_id", "interaction_type", "affected_pairs_count"],
      "properties": {
        "user_id": { "type": "string" },
        "interaction_type": { "type": "string", "enum": ["PURCHASE_INCREMENT", "DAILY_CRON_DECAY"] },
        "affected_pairs_count": { "type": "integer", "minimum": 0 }
      }
    }
  }
}